package com.atguigu.gulimall.zzmycanal.config;

import com.alibaba.otter.canal.protocol.CanalEntry;
import com.xpand.starter.canal.annotation.CanalEventListener;
import com.xpand.starter.canal.annotation.ListenPoint;

@CanalEventListener
public class UmsListening {
    @ListenPoint(schema = "gulimall_oms", table = {"ums_member"})
    public void ums_member(CanalEntry.RowData rowData) {
        System.err.println("ums_member");
        ShowObj.showData(rowData);
    }

    @ListenPoint(schema = "gulimall_oms", table = {"ums_integration_change_history"})
    public void ums_integration_change_history(CanalEntry.RowData rowData) {
        System.err.println("ums_integration_change_history");
        ShowObj.showData(rowData);
    }
    @ListenPoint(schema = "gulimall_oms", table = {"ums_member_collect_spu"})
    public void ums_member_collect_spu(CanalEntry.RowData rowData) {
        System.err.println("ums_member_collect_spu");
        ShowObj.showData(rowData);
    }
    @ListenPoint(schema = "gulimall_oms", table = {"ums_member_collect_subject"})
    public void ums_member_collect_subject(CanalEntry.RowData rowData) {
        System.err.println("ums_member_collect_subject");
        ShowObj.showData(rowData);
    }
    @ListenPoint(schema = "gulimall_oms", table = {"ums_member_statistics_info"})
    public void ums_member_statistics_info(CanalEntry.RowData rowData) {
        System.err.println("ums_member_statistics_info");
        ShowObj.showData(rowData);
    }

    @ListenPoint(schema = "gulimall_oms", table = {"ums_member_receive_address"})
    public void ums_member_receive_address(CanalEntry.RowData rowData) {
        System.err.println("ums_member_receive_address");
        ShowObj.showData(rowData);
    }
}
